package com.kang.product;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;

@Component
public class SpringProducer {

    // 这个 rocketMQTemplate 不光可以发消息，还可以主动拉pull消息。
    // RocketMQTemplate 默认是 push ，消费者也要用 push 模式，可以使用 @RocketMQMessageListener
    // 如果使用pull模式消费，请移除 @RocketMQMessageListener 和 RocketMQListener，再配置 DefaultLitePullConsumer
    @Resource
    private RocketMQTemplate rocketMQTemplate;

    /**
     * 普通发送
     * @param topic
     * @param msg
     */
    public void sendMessage(String topic,String msg){
        this.rocketMQTemplate.convertAndSend(topic,msg);
    }

}
